package com.me.kafka.exception;

import lombok.Data;

/**
 * 事务性生产消息失败
 * @author Wuzhiming
 */
@Data
public class KafkaProduceMessageException extends RuntimeException {

    private String message;

    public KafkaProduceMessageException(){

    }

    public KafkaProduceMessageException(String message) {
        this.message = message;
    }
}
